package com.echo.echovividlive.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import static com.echo.echovividlive.common.Constants.*;

@Slf4j
@Configuration
public class RabbitMQConfig {

    @Bean
    public Queue queueLike(){
        log.info("创建用户点赞信息队列...");
        return new Queue(USER_LIKE_QUEUE,true);
    }

    @Bean
    public Queue queueFans(){
        log.info("创建用户粉丝信息队列...");
        return new Queue(USER_FANS_QUEUE,true);
    }

    @Bean
    public Queue queueFollowing(){
        log.info("创建用户关注信息队列...");
        return new Queue(USER_FOLLOWING_QUEUE,true);
    }

    @Bean
    public Queue deleteVideo(){
        log.info("创建视频删除信息队列...");
        return new Queue(VIDEO_DELETE_QUEUE,true);
    }
}
